package cn.edu.flink.scala.tutorial.timestamp

import cn.edu.flink.scala.tutorial.source.AddSourceTest
import org.apache.flink.streaming.api.scala._
import cn.edu.flink.scala.tutorial.source.ClickSource

object AscendingTimestampsTest {
  def main(args: Array[String]): Unit = {
    val env = StreamExecutionEnvironment.createLocalEnvironmentWithWebUI()

    val stream = env.addSource(new ClickSource).assignAscendingTimestamps(_.timestamp)

    stream.print()

    env.execute("AscendingTimestampsTest")
  }
}
